// query.js
var MongoClient = require("mongodb").MongoClient;
var url = "mongodb://localhost:27017";
var db = null;
// 建立连接，cb 是回调函数
function connect(cb) {
  MongoClient.connect(url, function (err, client) {
    if (err) throw err;
    console.log("数据库已连接");
    db = client.db("myapp");
    // 连接成功后调用回调函数
    cb();
  });
}
// 由于 commonjs 无法动态获取模块内部内容，所以需要在使用 db 的时候调用 getDB 函数来获取。
function getDB() {
  return db;
}
module.exports = {
  connect: connect,
  getDB: getDB,
};